package pref.junx.flybird.network;

import pref.junx.flybird.api.RequestAPI;
import rx.Observable;
import rx.Observer;
import rx.android.schedulers.AndroidSchedulers;
import rx.schedulers.Schedulers;

/**
 * Created by JunX on 17/5/12.
 */

public class RequestNetWorks extends RetrofitUtils{

    // 网络请求接口实例化
    protected static final RequestAPI requestAPI = getRetrofit().create(RequestAPI.class);

    /********************************** 网络请求 **********************************/

    // 登录


    /********************************** 网络请求 **********************************/

    /**
     * 插入观察者
     * @param observable
     * @param observer
     * @param <T>
     */
    public static <T> void setSubscribe(Observable<T> observable, Observer<T> observer) {

        observable.subscribeOn(Schedulers.io())
                // 子线程访问网络
                .subscribeOn(Schedulers.newThread())
                // 回调主线程
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(observer);
    }

}
